package com.ibm.util;

public class TopologyStreamIds {
	public static final String BROADCAST_METADATA = "broadcast_metadata_stream";
	public static final String FEEDBACK_STREAM = "feedback_stream";
	public static final String RAW_DATA_STREAM = "raw_data_stream";
	public static final String PARSED_DATA_STREAM = "parsed_data_stream";
	public static final String PROCESSOR_SPOUT_STREAM = "processor_spout_stream";
	public static final String DATASOURCE_SPOUT_STREAM = "data_source_spout_stream";
	public static final String DATASOURCE_DELETE_SPOUT_STREAM = "data_source_delete_spout_stream";
	public static final String PROCESSOR_DELETE_SPOUT_STREAM = "processor_delete_spout_stream";
	public static final String METADATA_STREAM = "metadata_stream";
	public static final String METADATA_DELETE_STREAM = "metadata_delete_stream";
	public static final String DATAMESSAGE_STREAM = "data_message_stream";
	public static final String STREAM_TO_DISPATCH = "stream_to_dispatch";
	public static final String STREAM_TO_SEND = "stream_to_send";
	public static final String SQL_SPOUT_STREAM = "sql_spout_stream";
	public static final String SPARK_BATCH_ENDING = "spark_batch_ending";
}
